package org.framework.wu.framework.queue.listener;


import org.framework.wu.framework.queue.Message;

public interface QueueListener {

    /**
     * 监听数据
     * @param message 队列消息
     * @throws Exception
     */
    void listener(Message message) throws Exception;


    /**
     * 获取队列名称
     * @return 队列名称
     */
    String queueName();

    /**
     * 获取队列类型
     * @return 队列类型
     */
    String queueType();

    /**
     * 获取队列topic
     * @return 队列topic
     */
    String topic();

}
